package com.zjc.springboot.kafka;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.SubscribableChannel;

public interface ChannelDefinition {

    String TEST_STORM_OUTPUT = "testStorm-out-0";

    String TEST_STORM_INPUT = "testStorm-in-0";

    @Output(TEST_STORM_OUTPUT)
    SubscribableChannel testStormOutput();


    @Input(TEST_STORM_INPUT)
    SubscribableChannel testStormIn();
}
